package com.beidasoft.web.model.kafka;

import java.util.Date;

/**
 * Created by hoax on 2021-11-15 15:05.
 */
public class MsgForDataTrans {

    //消息序列号，用于保障消息处理连续性、准确性，保障顺序
    private Long messageIndex;
    //是否有前置消息完成要求（1：有，2：没有）
    private Integer isNeedPreMsg;
    //前置消息序列号,当isNeedPreMsg=1时使用
    private String preMsgIndex;
    //(01:数据同步 02:消息通知)
    private String messageType = "01";
    //消息触发时间
    private Date createTime;
    //(01:insert;02:update;03:logic delete;04:physics delete)
    private String optType;
    //用于辅助信息传递的字段，根据协议双方商议自定义内容规则（；例如“0a,11,00”可以根据’,’分割成三个字符串，作为三个控制开关）
    private String extraFlag;
    //数据内容，以 jsonArray string的形式存储
    private String data;

    public Long getMessageIndex() {
        return messageIndex;
    }

    public void setMessageIndex(Long messageIndex) {
        this.messageIndex = messageIndex;
    }

    public Integer getIsNeedPreMsg() {
        return isNeedPreMsg;
    }

    public void setIsNeedPreMsg(Integer isNeedPreMsg) {
        this.isNeedPreMsg = isNeedPreMsg;
    }

    public String getPreMsgIndex() {
        return preMsgIndex;
    }

    public void setPreMsgIndex(String preMsgIndex) {
        this.preMsgIndex = preMsgIndex;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public String getOptType() {
        return optType;
    }

    public void setOptType(String optType) {
        this.optType = optType;
    }

    public String getExtraFlag() {
        return extraFlag;
    }

    public void setExtraFlag(String extraFlag) {
        this.extraFlag = extraFlag;
    }

    public String getData() {
        return data;
    }

    public void setData(String data) {
        this.data = data;
    }
}
